fairnesscoop / permacoop

@QueryHandler(GetCustomersQuery)

export class GetCustomersQueryHandler {

  constructor(

    @Inject('ICustomerRepository')

    private readonly customerRepository: ICustomerRepository

  ) {}

  public async execute(

    query: GetCustomersQuery

  ): Promise<Pagination<CustomerView>> {

    const customerViews: CustomerView[] = [];

    const [customers, total] = await this.customerRepository.findCustomers(

      query.page

    );

    for (const customer of customers) {

      const address = customer.getAddress();

      customerViews.push(

        new CustomerView(

          customer.getId(),

          customer.getName(),

          new AddressView(

            address.getId(),

            address.getStreet(),

            address.getCity(),

            address.getZipCode(),

            address.getCountry()

          )

        )

      );

    }

    return new Pagination<CustomerView>(customerViews, total);